package com.shenma2009.recv;

import lombok.extern.slf4j.Slf4j;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

/**
 * @author 军哥
 * @version 1.0
 * @description: KafkaRecvMessage
 * @date 2023/5/22 17:46
 */
@Component
@Slf4j
public class KafkaRecvMessage {

    @KafkaListener(topics = "mytest")
    public void recvKafkaMessage(String msg) {
        System.out.println("recv:"+msg);
    }
}
